package com.syf.kit.soa.core.send.protocol.handle;

import com.syf.kit.soa.core.SyfRpcMsg;
import com.syf.kit.soa.core.send.protocol.TcpResponseCoordinator;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import lombok.extern.slf4j.Slf4j;

/**
 * 不维持长连接处理，需用完尽快关闭
 * */
@Slf4j
public class RpcSendHandler extends SimpleChannelInboundHandler<SyfRpcMsg> {

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, SyfRpcMsg respMsg) throws Exception {
        TcpResponseCoordinator.getInstance().onResponse(respMsg);
    }
}
